import com.shujia.util.SparkTool
import org.apache.spark.{SparkConf, SparkContext}

object TestSpark extends SparkTool {
  /**
    * 编写spark业务逻辑
    *
    */
  override def run(args: Array[String]): Unit = {
    sc.parallelize(List("java", "shujia")).foreach(println)
  }


  /**
    * 初始化方法，在子类设置spark运行时需要的参数
    * conf.setMaster("local")
    */
  override def init(): Unit = {
    conf.setMaster("local")
  }

}
